//package com.bw.kylin1705f.kafka;
//
//
//import org.apache.kafka.clients.consumer.ConsumerRecord;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//
//@Component
//public class MyKafkaListener {
//    Logger logger = LoggerFactory.getLogger(this.getClass());
//
//    @KafkaListener(topics="1705f")
//    public void consumer(ConsumerRecord consumerRecord){
//        logger.info(consumerRecord.value().toString());
//    }
//}
